use serde_json::{Map, Value};
use shq_common::prelude::{Callback, del_rept_tmp_talbe_in_ch};
use async_trait::async_trait;

pub struct KpiImportXgwclCallBack;
impl KpiImportXgwclCallBack {
    pub fn new() -> Self {
        KpiImportXgwclCallBack {}
    }
}
#[async_trait]
impl Callback for KpiImportXgwclCallBack {
        async fn after_save(
        &mut self,
        _map_val: Map<String, Value>,
        _tx: &mut sqlx::Transaction<'_,sqlx::MySql>
    ) -> anyhow::Result<()> {
        // 更新缓存
        del_rept_tmp_talbe_in_ch(&["khbb_zhjyjh".to_string()]).await?;
        Ok(())
    }
}